package com.codejiwei.flink.table.redis.source

import com.codejiwei.flink.table.redis.option.RedisLookupOptions
import org.apache.flink.api.common.serialization.DeserializationSchema
import org.apache.flink.table.connector.format.DecodingFormat
import org.apache.flink.table.connector.source.{DynamicTableSource, LookupTableSource}
import org.apache.flink.table.data.RowData
import org.apache.flink.table.types.DataType

/**
 * Author: codejiwei
 * Date: 2022/7/7
 * Desc:  
 * */
class RedisDynamicTableSource(
                             ) extends LookupTableSource {



  override def getLookupRuntimeProvider(lookupContext: LookupTableSource.LookupContext):
  LookupTableSource.LookupRuntimeProvider = ???

  override def copy(): DynamicTableSource = ???

  override def asSummaryString(): String = ???
}
